Node / reticulum_mirror / MeshChatX / files / meshchatx / src / backend / safe_rotating_file_handler.py

Displaying Raw • Download

T8b949e# SPDX-License-Identifier: 0BSD

T8b949e"""Rotating file log handler that survives EMFILE without cascading errors."""

Tff7b72from T7ee787__future__ Tff7b72import Te6edf3annotations

Tff7b72import T7ee787sys

Tff7b72from T7ee787loggingT7ee787.T7ee787handlers Tff7b72import Te6edf3RotatingFileHandler

Tff7b72class T56d364SafeRotatingFileHandlerTb4b4b4(Te6edf3RotatingFileHandlerTb4b4b4)Tb4b4b4:

T8b949e"""RotatingFileHandler that does not raise or thrash when FDs are exhausted.

After a failed reopen (common under Errno 24), fall back to stderr once

and skip further open attempts until a later emit succeeds at reopening.

"""

Tff7b72def Tff7b72__init__Tb4b4b4(Tff7b72selfTb4b4b4, Tff7b72*Te6edf3argsTb4b4b4, Tff7b72*Tff7b72*Te6edf3kwargsTb4b4b4)Tb4b4b4:

Tffa657superTb4b4b4(Tb4b4b4)Tff7b72.Td2a8ff__init__Tb4b4b4(Tff7b72*Te6edf3argsTb4b4b4, Tff7b72*Tff7b72*Te6edf3kwargsTb4b4b4)

Tff7b72selfTff7b72.Td2a8ff_open_failed Tff7b72= Tff7b72False

Tff7b72selfTff7b72.Td2a8ff_warned_open_failed Tff7b72= Tff7b72False

Tff7b72def Td2a8ff_openTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Tff7b72tryTb4b4b4:

Te6edf3stream Tff7b72= Tffa657superTb4b4b4(Tb4b4b4)Tff7b72.Td2a8ff_openTb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ff_open_failed Tff7b72= Tff7b72False

Tff7b72return Te6edf3stream

Tff7b72except Tf85149OSErrorTb4b4b4:

Tff7b72selfTff7b72.Td2a8ff_open_failed Tff7b72= Tff7b72True

Tff7b72raise

Tff7b72def Td2a8ffshouldRolloverTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3recordTb4b4b4)Tb4b4b4:

Tff7b72if Tff7b72selfTff7b72.Td2a8ff_open_failed Tff7b72and Tff7b72selfTff7b72.Td2a8ffstream Tff7b72is Tff7b72NoneTb4b4b4:

Tff7b72return Tff7b72False

Tff7b72tryTb4b4b4:

Tff7b72return Tffa657superTb4b4b4(Tb4b4b4)Tff7b72.Td2a8ffshouldRolloverTb4b4b4(Te6edf3recordTb4b4b4)

Tff7b72except Tf85149OSErrorTb4b4b4:

Tff7b72selfTff7b72.Td2a8ffstream Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ff_open_failed Tff7b72= Tff7b72True

Tff7b72return Tff7b72False

Tff7b72def Td2a8ffemitTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3recordTb4b4b4)Tb4b4b4:

Tff7b72tryTb4b4b4:

Tff7b72if Tff7b72selfTff7b72.Td2a8ffstream Tff7b72is Tff7b72None Tff7b72and Tff7b72not Tff7b72selfTff7b72.Td2a8ffdelayTb4b4b4:

Tff7b72tryTb4b4b4:

Tff7b72selfTff7b72.Td2a8ffstream Tff7b72= Tff7b72selfTff7b72.Td2a8ff_openTb4b4b4(Tb4b4b4)

Tff7b72except Tf85149OSErrorTb4b4b4:

Tff7b72selfTff7b72.Td2a8ff_open_failed Tff7b72= Tff7b72True

Tff7b72selfTff7b72.Td2a8ff_emit_fallbackTb4b4b4(Te6edf3recordTb4b4b4)

Tff7b72return

Tffa657superTb4b4b4(Tb4b4b4)Tff7b72.Td2a8ffemitTb4b4b4(Te6edf3recordTb4b4b4)

Tff7b72except Tf85149OSErrorTb4b4b4:

Tff7b72selfTff7b72.Td2a8ffstream Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ff_open_failed Tff7b72= Tff7b72True

Tff7b72selfTff7b72.Td2a8ff_emit_fallbackTb4b4b4(Te6edf3recordTb4b4b4)

Tff7b72def Td2a8ff_emit_fallbackTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3recordTb4b4b4) Tff7b72-Tff7b72> Tff7b72NoneTb4b4b4:

Tff7b72if Tff7b72not Tff7b72selfTff7b72.Td2a8ff_warned_open_failedTb4b4b4:

Tff7b72selfTff7b72.Td2a8ff_warned_open_failed Tff7b72= Tff7b72True

Tff7b72tryTb4b4b4:

Te6edf3sysTff7b72.Td2a8ffstderrTff7b72.Td2a8ffwriteTb4b4b4(

Ta5d6ff"Ta5d6ffmeshchatx: log file reopen failed (likely too many open files)Tffea00\nTa5d6ff"Tb4b4b4,

Tb4b4b4)

Tff7b72except Tf85149ExceptionTb4b4b4:

Tff7b72pass

Tff7b72tryTb4b4b4:

Te6edf3msg Tff7b72= Tff7b72selfTff7b72.Td2a8ffformatTb4b4b4(Te6edf3recordTb4b4b4)

Te6edf3sysTff7b72.Td2a8ffstderrTff7b72.Td2a8ffwriteTb4b4b4(Te6edf3msg Tff7b72+ Ta5d6ff"Tffea00\nTa5d6ff"Tb4b4b4)

Tff7b72except Tf85149ExceptionTb4b4b4:

Tff7b72pass